from celery_task1 import order_task,user_task




#异步任务
#提交一个给用户发短信的任务
# res=user_task.send_sms.delay('1985787845')
# print(res)



#提交一个取消订单的任务
# res=order_task.aaa.delay('订单取消成功')
# print(res)


#celery执行延时任务

#eta:延迟多长时间执行，eta需要传时间对象
#args是函数真正的传参
# celery执行延时任务
## 第一种方式：2021年1月7日17点3分12秒发送短信
# from datetime import datetime
# # # eta:延迟多长时间执行，eta需要传时间对象,并且是utc时间
# v1 = datetime(2021, 1, 7, 17, 3, 12)
# print(v1)
# v2 = datetime.utcfromtimestamp(v1.timestamp())
# print(v2)
# res=user_task.send_sms.apply_async(args=['18977654332',],eta=v2)


## 第二种方式：隔几秒后执行
from datetime import datetime
from datetime import timedelta
ctime = datetime.now()
# 默认用utc时间,所以要将时间进行一个转换
utc_ctime = datetime.utcfromtimestamp(ctime.timestamp())
time_delay = timedelta(seconds=10)
task_time = utc_ctime + time_delay
print(task_time)

res=user_task.send_sms.apply_async(args=['15464487'],eta=task_time)


#定时任务的配置
